var mysql = require("mysql");

//创建连接池
var pool = mysql.createPool({
  host: "localhost", //主机
  user: "root", //数据库用户名
  password: "root", //数据库密码
  port: 3306, //端口号
  database: "h52004", //数据库名字
  multipleStatements: true, //允许创建连接池：10连接对象
});

// pool.query("SELECT * FROM user_inf", function (error, rows) {
//   if (error) {
//     console.log(error);
//   } else {
//     console.log(rows);
//     let str = JSON.stringify(rows);
//     console.log(str);
//   }

//   if (error) {
//     console.log(error);
//     return;
//   }
//   console.log(rows);

//   if (error) throw error; //抛出异常
//   console.log(rows);
// });

//低配
// function query(sql, cb) {
//   //sql：sql语句;cb：回调函数
//   pool.query(sql, (error, rows) => {
//     if (error) throw error;
//     cb(rows); //函数的调用，实参
//   });
// }

//高配
function query(sql) {
  return new Promise((resolve, reject) => {
    //resolve：成功的回调  reject：失败的回调
    pool.query(sql, (err, res) => {
      if (err) reject(err);
      resolve(res);
    });
  });
}

module.exports = query;

//调用方法

// let sql = "SELECT * FROM user_inf WHERE name='malin'";
// query(sql, (result) => {
//   console.log(result);
// });
